8e391de074a22a580bd7074ca74aa592e86b2540,modules/riemann/src/main/java/com/spotify/ffwd/riemann/RiemannInputPlugin.java,RiemannInputPlugin,RiemannInputPlugin,#ProtocolFactory#RetryPolicy#,48
Before Change
.or(ProtocolFactory.defaultFor())
.protocol(DEFAULT_PROTOCOL, DEFAULT_PORT);
this.protocolServer = parseProtocolServer();
this.retry = Optional.fromNullable(retry).or(new RetryPolicy.Exponential());
}
private Class<? extends ProtocolServer> parseProtocolServer() {
After Change
.orElseGet(ProtocolFactory.defaultFor())
.protocol(DEFAULT_PROTOCOL, DEFAULT_PORT);
this.protocolServer = parseProtocolServer();
this.retry = Optional.ofNullable(retry).orElseGet(() -> new RetryPolicy.Exponential());
}
private Class<? extends ProtocolServer> parseProtocolServer() {